package com.bossien.flink.config;

import com.bossien.flink.interfaces.IExecutionHandlerConfig;
import org.apache.flink.api.java.DataSet;

/***
 * @author 胡春林
 * 批处理执行器
 */
public abstract   class ExecutionSetHandlerConfig<T> implements IExecutionHandlerConfig<T> {

    @Override
    public DataSet addSource() {
        return null;
    }

    @Override
    public abstract T executeFilter(T tClass);

    @Override
    public abstract T addSkin(T t);

}
